package com.spzx.order.configure;


import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

/**
 * 延迟消息：
 *  实现方式： 死信队列 + TTL
 */
@Configuration
public class DeadLetterMqConfig {

    // 声明一些变量

    public static final String exchange_dead = "exchange.dead"; //共用

    public static final String routing_dead_1 = "routing.dead.1"; //表示正常队列和交换机绑定的路由key
    public static final String routing_dead_2 = "routing.dead.2"; //表示死信队列和交换机绑定的路由key

    public static final String queue_dead_1 = "queue.dead.1"; //表示正常队列
    public static final String queue_dead_2 = "queue.dead.2"; //表示死信队列


    //1.声明交换机：共用
    @Bean
    public Exchange exchange(){
        return ExchangeBuilder.directExchange(exchange_dead)
                .durable(true) //持久化
                .build();
    }


    //2.声明死信队列
    @Bean
    public Queue queue1(){
        return QueueBuilder.durable(queue_dead_2).build();
    }


    //3.声明死信队列和交换机绑定
    @Bean
    public Binding binding1(){
        return BindingBuilder.bind(queue1()).to(exchange()).with(routing_dead_2).noargs();
    }



    //4.声明正常队列
    @Bean
    public Queue queue2(){
        // 设置如果队列一 出现问题，则通过参数转到exchange_dead，routing_dead_2 上！
        HashMap<String, Object> map = new HashMap<>();
        // 参数绑定 此处的key 固定值，不能随意写
        map.put("x-dead-letter-exchange", exchange_dead);
        map.put("x-dead-letter-routing-key", routing_dead_2);
        // 设置延迟时间
        map.put("x-message-ttl", 10 * 1000); // 10秒
        // 队列名称，是否持久化，是否独享、排外的【true:只可以在本次连接中访问】，是否自动删除，队列的其他属性参数
        //return new Queue(queue_dead_1, true, false, false, map);
        return QueueBuilder.durable(queue_dead_1).withArguments(map).build();
    }


    //5.声明正常队列和交换机绑定
    @Bean
    public Binding binding2(){
        return BindingBuilder.bind(queue2()).to(exchange()).with(routing_dead_1).noargs();
    }
}
